01957e8ab1fe83f2e7322cff5eebaf30607500cd,camel-core/src/main/java/org/apache/camel/processor/RedeliveryErrorHandler.java,RedeliveryErrorHandler,deliverToFailureProcessor,#Processor#boolean#Exchange#RedeliveryData#AsyncCallback#,777

Before Change


            // store the last to endpoint as the failure endpoint
            exchange.setProperty(Exchange.FAILURE_ENDPOINT, exchange.getProperty(Exchange.TO_ENDPOINT));
            // and store the route id so we know in which route we failed
            if (exchange.getUnitOfWork().getRouteContext() != null) {
                exchange.setProperty(Exchange.FAILURE_ROUTE_ID, exchange.getUnitOfWork().getRouteContext().getRoute().getId());
            }

            // the failure processor could also be asynchronous

After Change


            // store the last to endpoint as the failure endpoint
            exchange.setProperty(Exchange.FAILURE_ENDPOINT, exchange.getProperty(Exchange.TO_ENDPOINT));
            // and store the route id so we know in which route we failed
            UnitOfWork uow = exchange.getUnitOfWork();
            if (uow != null && uow.getRouteContext() != null) {
                exchange.setProperty(Exchange.FAILURE_ROUTE_ID, uow.getRouteContext().getRoute().getId());
            }